package KafkaTest

import (
	"goGrpc/helloService/Configs"
)

var configs = Configs.LoadConfig()

type kafkaConfigStruct struct {
	KafkaBrokers []string
	KafkaTopic   string
	GroupId      string
	Times        int
}

var KafkaConfigs = &kafkaConfigStruct{
	KafkaBrokers: []string{configs.GetString("kafka.address")},
	KafkaTopic:   configs.GetString("kafka.topic"),
	GroupId:      "csdn_test_1",
	Times:        0,
}
